package com.songjia.stream.test03;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

/**
 * 
 * 
 * @Description: 自定义订单流程接口
 *
 * @author: songjia 
 * @date: 2018年3月26日 下午4:14:27
 */
public interface OrderProcessor {

	// 输入通道名称
	public static final String INPUT_ORDER = "inputOrder";

	// 输出通道名称
	public static final String OUTPUT_ORDER = "outputOrder";

	/**
	 * 定义一个名为“inputOrder”的输入通道
	 * 
	 * @return
	 */
	@Input(INPUT_ORDER)
	SubscribableChannel inputOrder();

	/**
	 * 定义一个名为“outputOrder”的输出通道
	 * 
	 * @return
	 */
	@Output(OUTPUT_ORDER)
	MessageChannel outputOrder();

}
